75797d1d08393da3a74feda53977da7a20d346f8,cdap-data-fabric/src/main/java/co/cask/cdap/data/stream/service/LocalStreamService.java,LocalStreamService,runOneIteration,#,85
Before Change
Aggregator aggregator = aggregators.get(streamSpec.getName());
if (aggregator == null) {
// First time that we see this Stream here
aggregator = new Aggregator(streamSpec.getName(), 0);
aggregators.put(streamSpec.getName(), aggregator);
}
aggregator.checkAggregatedSize();
}
After Change
StreamSizeAggregator streamSizeAggregator = aggregators.get(streamSpec.getName());
if (streamSizeAggregator == null) {
// First time that we see this Stream here
streamSizeAggregator = createSizeAggregator(streamSpec.getName(), 0);
}
streamSizeAggregator.checkAggregatedSize();
}